ca6da0b0e397f22a1d730bffc0cc252a7513daaf,cdap-watchdog/src/main/java/co/cask/cdap/metrics/collect/AggregatedMetricsCollectionService.java,AggregatedMetricsCollectionService,runOneIteration,#,104
Before Change
final long timestamp = TimeUnit.SECONDS.convert(System.currentTimeMillis(), TimeUnit.MILLISECONDS);
LOG.trace("Start log collection for timestamp {}", timestamp);
final MetricsCollectorIterator metricsItor = new MetricsCollectorIterator(getMetrics(timestamp));
publishMetrics(timestamp, metricsItor);
}
After Change
final long timestamp = TimeUnit.SECONDS.convert(System.currentTimeMillis(), TimeUnit.MILLISECONDS);
LOG.trace("Start log collection for timestamp {}", timestamp);
publishMetrics(timestamp, getMetrics(timestamp));
}
private void publishMetrics(long timestamp, Iterator<MetricValues> metrics) {